package com.xxk.rocket.star.core.client;

import com.alibaba.rocketmq.client.consumer.MQConsumer;
import com.xxk.rocket.star.core.context.ConsumeContext;

public interface IProcessClientConsume {

  void processConsumeByContext(ConsumeContext consumeContext, MQConsumer mqConsumer)
          throws Throwable;
}
